package com.biz.mq.service.impl;

import com.biz.mq.service.*;
import lombok.*;
import org.apache.rocketmq.spring.core.*;

/**
 * @Description RocketMQ
 *
 * @Author liuxi
 * @Date 2024/6/30
 **/
@RequiredArgsConstructor
public class RocketMQMessageSender implements QueueService {

    private final RocketMQTemplate rocketMQTemplate;

    @Override
    public void send(String topic, String message) {
        rocketMQTemplate.convertAndSend(topic, message);
    }
}
